package com.qinglei.recoup.system.service;

import com.qinglei.recoup.common.domain.RadarMessage;

import com.baomidou.mybatisplus.extension.service.IService;
import com.qinglei.recoup.common.domain.RadarUserDataFour;
import com.qinglei.recoup.common.exception.RedisConnectException;
import com.qinglei.recoup.system.pojo.RealTimeDataVOV4;
import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.remoting.exception.RemotingException;


/**
 * @author dqh
 */
public interface RadarUserDataFourService extends IService<RadarUserDataFour> {

    /**
     * 保存用户雷达数据
     * @param message
     */
    void saveRadarUserData(RadarMessage message) throws MQBrokerException, RemotingException, InterruptedException, MQClientException, RedisConnectException;

    RealTimeDataVOV4 getRealTimeData(Integer bedId,Integer second, Integer tenantId) throws RedisConnectException;
}
